package com.kafka.dao;


import com.kafka.domain.OffsetInformation;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * @Author: Jiangxx
 * @Date: 2022/01/12
 * @Description:
 */
@Repository
public interface OffsetMapper {

    void insertOffset(List<OffsetInformation> offsetInformation);

    OffsetInformation selectOffset(@Param("partition") int partition, @Param("topic") String topic);
}
